072f0dfea9a06fdcf359cb16c7fde0976755b5fe,integration-tests/src/test/java/tachyon/client/RemoteBlockInStreamIntegrationTest.java,RemoteBlockInStreamIntegrationTest,readTest5,#,304
Before Change
long blockId = mTfs.getInfo(f).getBlockIds().get(0);
BlockInfo info = TachyonBlockStore.get().getInfo(blockId);
RemoteBlockInStream is =
new RemoteBlockInStream(info.getBlockId(), info.getLength(), info.getLocations().get(0)
.getWorkerAddress());
byte[] ret = new byte[k];
int start = 0;
while (start < k) {
After Change
long blockId = mTfs.getInfo(f).getBlockIds().get(0);
BlockInfo info = TachyonBlockStore.get().getInfo(blockId);
NetAddress workerAddr = info.getLocations().get(0).getWorkerAddress();
RemoteBlockInStream is =
new RemoteBlockInStream(info.getBlockId(), info.getLength(), new InetSocketAddress(
workerAddr.getHost(), workerAddr.getDataPort()));
byte[] ret = new byte[k];
int start = 0;
while (start < k) {